Node / meshtastic / Meshtastic-Android / files / app / src / main / java / com / geeksville / mesh / ui / settings / radio / CleanNodeDatabaseViewModel.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2025 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787com.geeksville.mesh.ui.settings.radio

Tff7b72import T7ee787androidx.lifecycle.ViewModel

Tff7b72import T7ee787androidx.lifecycle.viewModelScope

Tff7b72import T7ee787com.geeksville.mesh.database.NodeRepository

Tff7b72import T7ee787com.geeksville.mesh.database.entity.NodeEntity

Tff7b72import T7ee787com.geeksville.mesh.repository.datastore.RadioConfigRepository

Tff7b72import T7ee787dagger.hilt.android.lifecycle.HiltViewModel

Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow

Tff7b72import T7ee787kotlinx.coroutines.flow.asStateFlow

Tff7b72import T7ee787kotlinx.coroutines.launch

Tff7b72import T7ee787javax.inject.Inject

Tff7b72import T7ee787kotlin.time.Duration.Companion.days

Tff7b72import T7ee787kotlin.time.Duration.Companion.milliseconds

Tff7b72private Tff7b72const Tff7b72val Te6edf3MIN_DAYS_THRESHOLD Tff7b72= T79c0ff7f

T8b949e/**

* ViewModel for [CleanNodeDatabaseScreen]. Manages the state and logic for cleaning the node database based on

* specified criteria. The "older than X days" filter is always active.

*/

Tf0883e@HiltViewModel

Tff7b72class T56d364CleanNodeDatabaseViewModel

Tf0883e@Inject

Tff7b72constructorTb4b4b4(

Tff7b72private Tff7b72val Te6edf3nodeRepositoryTb4b4b4: Te6edf3NodeRepositoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3radioConfigRepositoryTb4b4b4: Te6edf3RadioConfigRepositoryTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3ViewModelTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3_olderThanDays Tff7b72= Te6edf3MutableStateFlowTb4b4b4(T79c0ff3T79c0ff0fTb4b4b4)

Tff7b72val Te6edf3olderThanDays Tff7b72= Te6edf3_olderThanDaysTb4b4b4.Te6edf3asStateFlowTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3_onlyUnknownNodes Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Tff7b72falseTb4b4b4)

Tff7b72val Te6edf3onlyUnknownNodes Tff7b72= Te6edf3_onlyUnknownNodesTb4b4b4.Te6edf3asStateFlowTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3_nodesToDelete Tff7b72= Te6edf3MutableStateFlowTff7b72<Te6edf3ListTff7b72<Te6edf3NodeEntityTff7b72>Tff7b72>Tb4b4b4(Te6edf3emptyListTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3nodesToDelete Tff7b72= Te6edf3_nodesToDeleteTb4b4b4.Te6edf3asStateFlowTb4b4b4(Tb4b4b4)

Tff7b72fun Td2a8ffonOlderThanDaysChangedTb4b4b4(Te6edf3valueTb4b4b4: Tffa657FloatTb4b4b4) Tb4b4b4{

Te6edf3_olderThanDaysTb4b4b4.Te6edf3value Tff7b72= Te6edf3value

Tb4b4b4}

Tff7b72fun Td2a8ffonOnlyUnknownNodesChangedTb4b4b4(Te6edf3valueTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{

Te6edf3_onlyUnknownNodesTb4b4b4.Te6edf3value Tff7b72= Te6edf3value

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3value Tff7b72&Tff7b72& Te6edf3_olderThanDaysTb4b4b4.Te6edf3value Tff7b72< Te6edf3MIN_DAYS_THRESHOLDTb4b4b4) Tb4b4b4{

Te6edf3_olderThanDaysTb4b4b4.Te6edf3value Tff7b72= Te6edf3MIN_DAYS_THRESHOLD

Tb4b4b4}

Tb4b4b4}

T8b949e/**

* Updates the list of nodes to be deleted based on the current filter criteria. The logic is as follows:

* - The "older than X days" filter (controlled by the slider) is always active.

* - If "only unknown nodes" is also enabled, nodes that are BOTH unknown AND older than X days are selected.

* - If "only unknown nodes" is not enabled, all nodes older than X days are selected.

* - Nodes with an associated public key (PKI) heard from within the last 7 days are always excluded from deletion.

* - Nodes marked as ignored or favorite are always excluded from deletion.

*/

Tff7b72fun Td2a8ffgetNodesToDeleteTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{

Tff7b72val Te6edf3onlyUnknownEnabled Tff7b72= Te6edf3_onlyUnknownNodesTb4b4b4.Te6edf3value

Tff7b72val Te6edf3currentTimeSeconds Tff7b72= Te6edf3SystemTb4b4b4.Te6edf3currentTimeMillisTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3millisecondsTb4b4b4.Te6edf3inWholeSeconds

Tff7b72val Te6edf3sevenDaysAgoSeconds Tff7b72= Te6edf3currentTimeSeconds Tff7b72- T79c0ff7.Te6edf3daysTb4b4b4.Te6edf3inWholeSeconds

Tff7b72val Te6edf3olderThanTimestamp Tff7b72= Te6edf3currentTimeSeconds Tff7b72- Te6edf3_olderThanDaysTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3daysTb4b4b4.Te6edf3inWholeSeconds

Tff7b72val Te6edf3initialNodesToConsider Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3onlyUnknownEnabledTb4b4b4) Tb4b4b4{

T8b949e// Both "older than X days" and "only unknown nodes" filters apply

Tff7b72val Te6edf3olderNodes Tff7b72= Te6edf3nodeRepositoryTb4b4b4.Te6edf3getNodesOlderThanTb4b4b4(Te6edf3olderThanTimestampTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3unknownNodes Tff7b72= Te6edf3nodeRepositoryTb4b4b4.Te6edf3getUnknownNodesTb4b4b4(Tb4b4b4)

Te6edf3olderNodesTb4b4b4.Te6edf3filter Tb4b4b4{ Te6edf3itNode Tff7b72-Tff7b72> Te6edf3unknownNodesTb4b4b4.Te6edf3any Tb4b4b4{ Te6edf3unknownNode Tff7b72-Tff7b72> Te6edf3itNodeTb4b4b4.Te6edf3num Tff7b72=Tff7b72= Te6edf3unknownNodeTb4b4b4.Te6edf3num Tb4b4b4} Tb4b4b4}

Tb4b4b4} Tff7b72else Tb4b4b4{

T8b949e// Only "older than X days" filter applies

Te6edf3nodeRepositoryTb4b4b4.Te6edf3getNodesOlderThanTb4b4b4(Te6edf3olderThanTimestampTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Te6edf3_nodesToDeleteTb4b4b4.Te6edf3value Tff7b72=

Te6edf3initialNodesToConsiderTb4b4b4.Te6edf3filterNot Tb4b4b4{ Te6edf3node Tff7b72-Tff7b72>

T8b949e// Exclude nodes with PKI heard in the last 7 days

Tb4b4b4(Te6edf3nodeTb4b4b4.Te6edf3hasPKC Tff7b72&Tff7b72& Te6edf3nodeTb4b4b4.Te6edf3lastHeard Tff7b72>Tff7b72= Te6edf3sevenDaysAgoSecondsTb4b4b4) Tff7b72|Tff7b72|

T8b949e// Exclude ignored or favorite nodes

Te6edf3nodeTb4b4b4.Te6edf3isIgnored Tff7b72|Tff7b72|

Te6edf3nodeTb4b4b4.Te6edf3isFavorite

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

T8b949e/**

* Deletes the nodes currently queued in [_nodesToDelete] from the database and instructs the mesh service to remove

* them.

*/

Tff7b72fun Td2a8ffcleanNodesTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3viewModelScopeTb4b4b4.Te6edf3launch Tb4b4b4{

Tff7b72val Te6edf3nodeNums Tff7b72= Te6edf3_nodesToDeleteTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3num Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3nodeNumsTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3nodeRepositoryTb4b4b4.Te6edf3deleteNodesTb4b4b4(Te6edf3nodeNumsTb4b4b4)

Tff7b72val Te6edf3service Tff7b72= Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3meshService

Tff7b72if Tb4b4b4(Te6edf3service Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{

Tff7b72for Tb4b4b4(Te6edf3nodeNum Tff7b72in Te6edf3nodeNumsTb4b4b4) Tb4b4b4{

Te6edf3serviceTb4b4b4.Te6edf3removeByNodenumTb4b4b4(Te6edf3serviceTb4b4b4.Te6edf3packetIdTb4b4b4, Te6edf3nodeNumTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

T8b949e// Clear the list after deletion or if it was empty

Te6edf3_nodesToDeleteTb4b4b4.Te6edf3value Tff7b72= Te6edf3emptyListTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}